#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Datetime: 2022/9/26 11:25
# @Author  : CHENWang
# @Site    : 
# @File    : hourly_get_usdt_premium_data.py
# @Software: PyCharm

"""
脚本说明: usdt_premium_data_update 每小时运行
"""

from TQR_Applications.factor_database.crypto.trading_data_update import usdt_premium_data_update
from logger import logger
import os, traceback
from task_monitor import task_to_db, send_error_to_email


if __name__ == '__main__':
    # 获取usdt otc 兑 人民币价格
    # 数据需要网站爬取，部分数据（5m频）因为网站上不会保留那么久，因此需要每天爬取
    logger.info("开始usdt_premium_data_update")
    task_to_db(os.path.basename(__file__), 'usdt_premium_data_update')
    try:
        usdt_premium_data_update()
    except Exception as e:
        msg = traceback.format_exc()
        logger.info(msg)
        send_error_to_email(script_name=os.path.basename(__file__), func_name="usdt_premium_data_update", message=msg)
        raise e
    task_to_db(os.path.basename(__file__), 'usdt_premium_data_update', 1)
    logger.info("成功usdt_premium_data_update")